package com.chis.activemq;

import com.zendesk.maxwell.MaxwellContext;
import com.zendesk.maxwell.producer.AbstractProducer;
import com.zendesk.maxwell.producer.ProducerFactory;

public class ActiveMqProducerFactory implements ProducerFactory {
    @Override
    public AbstractProducer createProducer(MaxwellContext maxwellContext) {
        return new ActiveMqProducer(maxwellContext);
    }
}
